e4290657ce49a7625079270f3ba9baa8783c98fe,src/java/org/apache/cassandra/net/OutboundTcpConnection.java,OutboundTcpConnection,connect,#,159
Before Change
// zero means 'bind on any available port.'
if (DatabaseDescriptor.getEncryptionOptions().internode_encryption == EncryptionOptions.InternodeEncryption.all)
{
socket = SSLFactory.getSocket(DatabaseDescriptor.getEncryptionOptions(), endpoint, DatabaseDescriptor.getStoragePort(), FBUtilities.getLocalAddress(), 0);
}
else {
socket = new Socket(endpoint, DatabaseDescriptor.getStoragePort(), FBUtilities.getLocalAddress(), 0);
After Change
try
{
// zero means 'bind on any available port.'
EncryptionOptions options = DatabaseDescriptor.getEncryptionOptions();
if (options != null && options.internode_encryption == EncryptionOptions.InternodeEncryption.all)
{
socket = SSLFactory.getSocket(options, endpoint, DatabaseDescriptor.getStoragePort(), FBUtilities.getLocalAddress(), 0);
}